//package net.xmmpp.uc.im.broker.dao;
//
//
//import MessageBean;
//import MessageXmpp;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.data.mongodb.core.MongoOperations;
//import org.springframework.stereotype.Repository;
//
//@Repository
//public class MessageDAO {
//
//    @Autowired
//    private MongoOperations mongoTemplate;
//
//    private final static String COLLECTION_MSG = "message";
//
//    private final static String COLLECTION_GROUP_MSG = "group_message";
//
//    public void insertOne(MessageXmpp xmpp){
//        MessageBean msgBean = new MessageBean();
//        msgBean.setVersion(xmpp.getVersion());
//        msgBean.setXmpp(xmpp.getXmpp());
//        msgBean.setType(xmpp.getType());
//
//        if(xmpp.getType() == 0){
//            String to = xmpp.getTo();
//            String from = xmpp.getFrom();
//
//            if(to != null && !to.isEmpty()){
//                msgBean.setUid(to);
//                msgBean.setFrdUid(from);
//                mongoTemplate.insert(msgBean, COLLECTION_MSG);
//            }
//
//            if(from != null && !from.isEmpty()) {
//                msgBean.setUid(from);
//                msgBean.setFrdUid(to);
//                mongoTemplate.insert(msgBean, COLLECTION_MSG);
//            }
//        }else{
//            if(xmpp.getTo() != null && !xmpp.getTo().isEmpty()) {
//                msgBean.setUid(xmpp.getTo());
//                msgBean.setFrdUid(xmpp.getFrom());
//                mongoTemplate.insert(msgBean, COLLECTION_GROUP_MSG);
//            }
//        }
//    }
//
//}
